package com.explame.d01_Environment_处理环境;

import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.junit.jupiter.api.Test;

public class env {
    //批处理环境
    @Test
    public void Env1(){
        ExecutionEnvironment benv = ExecutionEnvironment.getExecutionEnvironment();
    }

    //流处理环境
    @Test
    public void Env2(){
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        System.out.println(1);
    }
}
